package bsp.scan;


import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.io.Text;

import util.ScanMessage;
import util.functors.OpScan;
import bsp.BspHelper;

public abstract class BspScanHelper extends BspHelper<LongWritable, Text, Text, NullWritable, ScanMessage> {

	protected String inputPath;
	protected String outputPath;
	protected OpScan<? extends Number > oplus;
	
	public abstract void setOperator();
	public BspScanHelper(){
		setOperator();
	}
	
	@Override
	public void setAllCMappers() {
 		this.addMapper(new ScanStepOne(oplus)); //oplus
     	this.addMapper(new ScanStepTwo(oplus));
		
	}
}
